package com.qf.smsplatform.strategy.config;

import com.qf.smsplatform.common.constants.RabbitMQConstants;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * projectName: sms-platform
 *
 * @author: 黄睿武
 * time: 2021/8/14 20:41
 * description:  声明发送写日志队列,和状态报告推送队列
 */

@Configuration
public class RabbitMQConfig {

    @Bean
    public Queue sendLogQueue(){
        return QueueBuilder.durable(RabbitMQConstants.TOPIC_SMS_SEND_LOG).build();
    }

    @Bean
    public Queue sendReportQueue(){
        return QueueBuilder.durable(RabbitMQConstants.TOPIC_PUSH_SMS_REPORT).build();
    }
}
